package producerAndConsumer;

/**
 * <pre>
 * 功能描述：
 * </pre>
 *
 * @author: 李明杰
 * @date: 2023/4/29 16:37
 */
public class Producer extends Thread {

    public void run() {
        try {
            Thread.sleep(1000);//模拟程序执行
            String result = Thread.currentThread().getName() + "线程执行完毕，输出结果";
            Container.arrayBlockingQueue.put(result);//超过阻塞队列最大阈值时阻塞，一直阻塞
//            if(!Container.arrayBlockingQueue.offer(result, 5, TimeUnit.SECONDS)) {//规定时间内数据入队失败
//                System.err.println("数据入队失败");
//            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}
